package site.brucewu.aha.controller.kafka;

//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Service;
//
//@Service
public class KafkaConsumerService {

//    @KafkaListener(topics = "topic1", groupId = "my-group")
//    public void listen(String message) {
//        System.out.println("Received message: " + message);
//    }
}
